package com.itcam.cannal;

import com.alibaba.otter.canal.client.CanalConnector;
import com.alibaba.otter.canal.client.CanalConnectors;

import java.net.InetSocketAddress;

public class SimpleCanalClientExample {

    public static void main(String[] args) {
        // 创建链接
        CanalConnector connector = CanalConnectors.newSingleConnector(
                new InetSocketAddress("192.168.254.156",
                        11111),
                "example",
                "",
                "");
        int batchSize = 1000;
        int emptyCount = 0;
    }
}